package com.cailu.receiver.config;

import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

import com.cailu.common.constant.DelaySenderQueuesCommon;

/**
 * @author cailu
 * @filename DelaySenderQueuesReceiver
 * @description 延迟消费 在【队列上】
 * @date 2020/3/31 15:12
 */
@Component
public class DelaySenderQueuesReceiver {

	/**
	 * 功能描述  监听 【队列上】 延迟消费
	 * @param str 内容
	 * @return void
	 * @author cailu
	 * @date 2020/3/31 15:14
	 */
	@RabbitListener(queues = DelaySenderQueuesCommon.DELAY_QUEUES_QUEUE_NAME)
	public void processQueue(String str) {
		System.out.println("Receive---delay_queues_queue_name:========================:" + str.toString());
	}
}
